package com.gkoudai.service;

import com.alibaba.fastjson.JSONObject;
import com.gkoudai.open.platform.common.CategoryCommon;
import com.gkoudai.open.platform.entry.SocketResponseBean;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Component;

import java.util.Objects;

/**
 * @author wangqi
 * @date 2025-05-12 16:30
 */
@Slf4j
@Component
public class NewsService {

    public void subscriptionNewsResponse(SocketResponseBean socketResponseBean) {
        //TODO  订阅结果返回后的自定义操作
    }


    public void NewsResponse(JSONObject data) {
        String dataType = data.getString("dataType");
        if (StringUtils.isBlank(dataType)) {
            log.info("新增资讯:{}", data.toJSONString());
            //TODO 新增的资讯数据业务操作
        }
        if (CategoryCommon.DataType.UPDATE.getDataType().equals(dataType)) {
            log.info("更新资讯:{}", data.toJSONString());
            //TODO 资讯更新业务操作
        }
        if (CategoryCommon.DataType.DELETE.getDataType().equals(dataType)) {
            log.info("删除资讯:{}", data.toJSONString());
            //TODO 资讯删除业务操作
        }
    }

}
